Amazon FSx for Windows のファイルシステムステータスを監視する Lambda 関数を作成してみた

片方裕人

2024.06.10

はじめに

テクニカルサポートの片方です。

Amazon FSx for Windows のファイルシステムステータスを監視する Lambda 関数を作成してみた。当該状態を監視する Lambda 関数を使って、CloudWatch カスタムメトリクスとして表示させます。
お好みで EventBridge による Lambda 関数の定期実行や CloudWatch アラームより SNS を使用した通知などをご検討ください。

構成と説明

Amazon FSx for Windows のサーバー状態を監視する Lambda 関数を作成します。それをカスタムメトリクスとして取得し CloudWatch に送信して表示させます。

以下はイメージです。(本ブログでは赤枠で囲んだ範囲についてご紹介します)

やってみた

ロール

ロール名: LambdaFunctionCheckFSxWindowsFileSystemStatusRole

Lambda 関数にアタッチするロールを作成します。信頼関係は以下です。

{
    "Version": "2008-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": "lambda.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
        }
    ]
}

アタッチするポリシー例

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "*",
            "Effect": "Allow"
        },
        {
            "Action": [
                "cloudwatch:PutMetricData",
                "fsx:DescribeFileSystems"
            ],
            "Resource": "*",
            "Effect": "Allow"
        }
    ]
}

Lambda 関数

Lambda 関数を作成します。ランタイムは Python 3.12 を使用しました。以下を参考に作成してます。

関数名: LambdaFunctionCheckFSxWindowsFileSystemStatus

アタッチする実行ロールは、先ほど作成した "LambdaFunctionCheckFSxWindowsFileSystemStatusRole" を選択します。

サンプルコード

import boto3
from botocore.exceptions import ClientError

def send_cw_metric(metric_dimension_value, metric_value):
    client = boto3.client('cloudwatch')
    try:
        response = client.put_metric_data(
            Namespace='Custom/FSxWindows',
            MetricData=[
                {
                    'MetricName': 'FSxForWindowsStatus',
                    'Dimensions': [
                        {
                            'Name': 'FileSystemId',
                            'Value': metric_dimension_value
                        }
                    ],
                    'Value': metric_value,
                    'Unit': 'Count'
                },
            ]
        )
        print("Successfully sent metric data:", response)
    except ClientError as e:
        print("Failed to send metric data:", e)

def lambda_handler(event, context):
    status_map = {
        'AVAILABLE': 0,
        'CREATING': 1,
        'FAILED': 2,
        'DELETING': 3,
        'MISCONFIGURED': 4,
        'UPDATING': 5,
        'MISCONFIGURED_UNAVAILABLE': 6,
    }

    client = boto3.client('fsx')
    paginator = client.get_paginator('describe_file_systems')
    try:
        for page in paginator.paginate():
            file_systems = page.get('FileSystems', [])
            for fs in file_systems:
                send_cw_metric(fs.get('FileSystemId'), status_map.get(fs.get('Lifecycle'), -1))
    except ClientError as e:
        print("Failed to describe file systems:", e)

以上で実装は終了です。お疲れさまでした。

検証してみた

結果はご覧の通り問題なく AVAILABLE: 0 として取得できています。成功です。

※ 作成中 (CREATING: 1)

※ 削除中 (DELETING: 3)

まとめ

ご自身の環境に合わせ適宜修正の上ご利用ください。本ブログが誰かの参考となれば幸いです。

参考資料

アノテーション株式会社について

アノテーション株式会社は、クラスメソッド社のグループ企業として「オペレーション・エクセレンス」を担える企業を目指してチャレンジを続けています。「らしく働く、らしく生きる」のスローガンを掲げ、様々な背景をもつ多様なメンバーが自由度の高い働き方を通してお客様へサービスを提供し続けてきました。現在当社では一緒に会社を盛り上げていただけるメンバーを募集中です。少しでもご興味あれば、アノテーション株式会社WEBサイトをご覧ください。